e55f4f44cfdc01a7a3268bedb5fd317ee3687b6e,tests/test_apps/kafkaimporter/db/procedures/InsertExport.java,InsertExport,run,#number#number#,54
Before Change
// voltQueueSQL(importInsert, key, value);
// Execute queued statements
voltExecuteSQL(true);
return 0;
}
}
After Change
voltQueueSQL(exportInsert, key, value);
voltQueueSQL(mirrorInsert, key, value);
voltQueueSQL(selectCounts);
VoltTable[] result = voltExecuteSQL();
VoltTable data = result[2];
long nrows = data.getRowCount();
if (nrows > 0) {
long ck = data.fetchRow(0).getLong(0);
voltQueueSQL(updateCounts, 1l, ck);
voltExecuteSQL(true);
} else {
voltQueueSQL(insertCounts, key, 1l);
voltExecuteSQL(true);
}
// Execute queued statements